<?php
namespace Home\Controller;
use Think\Controller;

/**
 * 用于检测业务代码死循环或者长时间阻塞等问题
 * 如果发现业务卡死，可以将下面declare打开（去掉//注释），并执行php start.php reload
 * 然后观察一段时间workerman.log看是否有process_timeout异常
 */
//declare(ticks=1);

/**
 * 聊天主逻辑
 * 主要是处理 onMessage onClose
 */
use GatewayWorker\Lib\Gateway;
// use GatewayWorker\Lib\DbConnection;


class EventsController
{
   /**
    * 有消息时
    * @param int $client_id
    * @param mixed $message
    */
   public static function onMessage($client_id, $message)
   {
      //   $panel_data = F('gd_panel_data');
      //   if(!$panel_data){
         $gd_panel_data = update_panel_data();
         $gx_panel_data = gx_update_panel_data();
         // }
         $data = [
            'type'=>'data',
            'data'=>['gd'=>$gd_panel_data,'gx'=>$gx_panel_data]
         ];
        Gateway::sendToClient($client_id, json_encode($data));
   }

}